<?php

require_once 'vendor/autoload.php';

use Pheanstalk\Pheanstalk;

/**
 * 连接服务
 * 参数一: 服务器地址
 * 参数二: 端口号, 默认 11300
 */
$pheanstalk = new Pheanstalk('127.0.0.1', 11300);


$tube = $pheanstalk->useTube('jobPut');

/*
* put
* 参数一: 任务内容(string)
* 参数二(可选): 任务优先级, 默认1024, 取值范围 0-1024 值越小, 优先级越高(int)
* 参数三(可选): 任务延迟时间, 默认为 60, 单位: 秒
* 功能: 生产任务
* 返回值: 任务 id (int)
*/
$tube->put('zhangsan');
$tube->put('lisi');

/*
* putInTube
* 参数一: 管道名(string)
* 参数二: 任务内容(string)
* 参数三(可选): 任务优先级, 默认1024, 取值范围 0-1024 值越小, 优先级越高(int)
* 参数四(可选): 任务延迟时间, 默认为 60, 单位: 秒
* 功能: 生产任务
* 返回值: 任务 id (int)
*/
$pheanstalk->putInTube('jobPut', 'wangtu');
$pheanstalk->useTube('jobPut')->put('zhaoliu');

print_r($pheanstalk->statsTube('jobPut'));
